package com.spark.util.example

import com.spark.util.core.Sparking

/**
 * TopN问题
 */
object TopNExample extends Sparking {

  def main(args: Array[String]): Unit = {
    val rdd = getSparkSession(None)
      .sparkContext
      .parallelize(Array(("sivela", 15),("sivela", 18),("sivela", 16),("Alice", 15),("Bob", 18)))
    rdd.foreach(println(_))
  }

}
